package com.example.d10_homework.homework02;

import java.io.*;
import java.net.Socket;
import java.util.Scanner;

/**
 * 生产着
 */
public class Producer {
    public static void main(String[] args) throws Exception {
        // 创建一个Socket连接到本地主机的指定端口
        Socket socket = new Socket("127.0.0.1", 5672);

        // 获取Socket的输出流,并包装为BufferedWriter以便于写操作
        BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));

        // 向服务器标识自己为producer
        bw.write("producer");
        bw.newLine();
        bw.flush();

        // 创建Scanner对象以读取控制台输入
        Scanner sc = new Scanner(System.in);

        // 无限循环,持续读取用户输入并发送到Socket
        while (true) {
            // 提示用户输入消息
            System.out.println("请输入要发送的消息：");
            // 读取用户输入的消息
            String msg = sc.nextLine();
            // 将消息写入Socket的输出流并发送
            bw.write(msg);
            bw.newLine();
            bw.flush();
        }
    }
}
